package cn.iotab.iotkit.transport.api.access.handler;

import cn.iotab.iotkit.transport.api.access.model.message.DeviceMessage;
import cn.iotab.iotkit.transport.api.access.model.message.DeviceMessageReply;
import com.google.common.util.concurrent.ListenableFuture;

/**
 * 上行，设备消息的处理器
 */
public interface DeviceMessageHandler {

    String PRODUCT_KEY_DEFAULT = "*";

    ListenableFuture<DeviceMessageReply> process(DeviceMessage message);
}
